package com.wisdytech.ccdserver.bucket.serveice;

import com.baomidou.mybatisplus.extension.service.IService;
import com.wisdytech.ccdserver.bucket.dto.BucketTaskDto;
import com.wisdytech.ccdserver.bucket.dto.MinitorBucketViewDto;
import com.wisdytech.ccdserver.bucket.dto.TableBuckets;
import com.wisdytech.ccdserver.bucket.model.BucketTask;
import com.wisdytech.common.bean.Filter;
import com.wisdytech.common.bean.MultiResultResponse;
import com.wisdytech.common.bean.UniqueResultResponse;

import java.util.List;


public interface IBucketTaskService extends IService<BucketTask> {
    void saveBucketTask(Filter filter, String taskid);

    int srarchPushtasks(Filter filter);

    String checkBucketIsNull(Filter filter);

    UniqueResultResponse deleteBucketTaskByIds(Filter filter);

    void asyncBucketTaskByIds();


    UniqueResultResponse interruptBucketTaskByIds(Filter filter);


    MultiResultResponse findTaskAndSearchProgress(Filter filter);

    void updateInterRuptFlag(String taskId);

    void updateOkFlag(String taskId);

    void updateBucketTaskMbvByTaskId(BucketTaskDto bucketTaskDto, MinitorBucketViewDto mbv);
}
